/**
 * @author 陈泰来
 * @version V1.0
 * @Project echo-java-base
 * @Title 消费者
 * @Description *
 * @Package concurrent.blockingQueue.bqtest2
 * @date 2021/3/22 3:30 下午
 * @Copyright:学如逆水行舟，不进则退 .
 */
package concurrent.blockingQueue.bqtest2;

import java.text.MessageFormat;

public class Consumer implements Runnable {

    DoubleEndedDeque<String> doubleEndedDeque;


    public Consumer(DoubleEndedDeque<String> doubleEndedDeque) {
        this.doubleEndedDeque = doubleEndedDeque;
    }


    @Override
    public void run() {
        for (; ; ) {
            doubleEndedDeque.take();
        }


    }
}
